package com.haozhen.datasource;

import org.apache.flink.streaming.api.environment.LocalStreamEnvironment;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @author haozhen
 * @email haozh@ync1.com
 * @date 2021/2/9  11:12
 */
public class SourceFromFile {

    public static void main(String[] args) {
        String inputPath = "data/input/hello.txt";
        StreamExecutionEnvironment executionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment();

        executionEnvironment.readTextFile(inputPath);

    }
}
